package ee.ts022.tuum.services.jms;

import javax.jms.JMSException;
import javax.jms.Message;

import org.springframework.jms.core.MessagePostProcessor;

public class JmsPostProcessor implements MessagePostProcessor {
	
	private String correlationId;
	
	public JmsPostProcessor(String correlationId) {
		this.correlationId = correlationId;
	}

	@Override
	public Message postProcessMessage(Message message) throws JMSException {
		message.setJMSCorrelationID( correlationId );
        return message;
	}


}
